for the test CD, and simplifies DevController everso slightly. It ought to be
generally useful, too.
Signed-off-by: Ewan Mellor <ewan@xensource.com>
## private:
- def onReleaseDomain(self):
+ def onReleaseDomain(self, _):
self.domains_lock.acquire()
try:
self.refresh()
return []
- def storeChanged(self):
+ def storeChanged(self, _):
log.trace("XendDomainInfo.storeChanged");
changed = False
ev = Event()
result = { 'status': Timeout }
- xswatch(statusPath, hotplugStatusCallback, statusPath, ev, result)
+ xswatch(statusPath, hotplugStatusCallback, ev, result)
ev.wait(DEVICE_CREATE_TIMEOUT)
return result['status']
try:
we = xs.read_watch()
watch = we[1]
- res = watch.fn(*watch.args, **watch.kwargs)
+ res = watch.fn(we[0], *watch.args, **watch.kwargs)
if not res:
watch.unwatch()
except: